package main

import (
	"context"
	"crypto/md5"
	"fmt"
	"google.golang.org/grpc"
	"huayan.com/src/test"
	"net"
)

func main() {
	//tcp监听
	lis, _ := net.Listen("tcp", ":8028")
	//创建gRPC服务
	s := grpc.NewServer()
	//注册服务
	test.RegisterWriterServer(s, &server{})
	//服务启动在指定端口上
	s.Serve(lis)
}

//以下实现test.pb.go中的接口
type server struct {
}
func (s *server) DoMD5(ctx context.Context, req *test.Req) (*test.Res, error) {
	fmt.Println("MD5方法请求JSON:" + req.JsonStr)
	return &test.Res{
		BancJson: "MD5 :" + fmt.Sprintf("%x", md5.Sum([]byte(req.JsonStr))),
	}, nil
}
func (s *server) DoStr(ctx context.Context, req *test.Req) (*test.Res, error) {
	fmt.Println("MD5方法请求JSON:" + req.JsonStr)
	return &test.Res{
		BancJson: "请求字符串 :" + req.JsonStr,
	}, nil
}
